SparkN0de-git - /page/commit.mu

Micron Document

--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

| SparkN0de-git | SparkN0de |

Node / ReticulumProjects / LXMF.git / commits / c2a08ef

Commit c2a08ef35588ccd512a7ea7c9898c83e5fd2864e

󰉖 Browse tree at this commit

Parents : 1430b1c

Author : Mark Qvist <mark@unsigned.io>

Date : 2025-01-21T20:44:11+01:00

Enqueue and batch process distribution queue mappings

Changes

1 files changed, 10 insertions(+), 9 deletions(-)

M LXMF/LXMRouter.py +10 -9

Diff

diff --git a/LXMF/LXMRouter.py b/LXMF/LXMRouter.py

index 1e62914..ee1dca8 100644

--- a/LXMF/LXMRouter.py

+++ b/LXMF/LXMRouter.py

@@ -656,15 +656,16 @@ class LXMRouter:

time.sleep(LXMRouter.PROCESSING_INTERVAL)

def flush_queues(self):

- self.flush_peer_distribution_queue()

- RNS.log("Calculating peer distribution queue mappings...", RNS.LOG_DEBUG); st = time.time()

- for peer_id in self.peers.copy():

- if peer_id in self.peers:

- peer = self.peers[peer_id]

- if peer.queued_items():

- peer.process_queues()

- RNS.log(f"Distribution queue mapping completed in {RNS.prettytime(time.time()-st)}", RNS.LOG_DEBUG)

+ if len(self.peers) > 0:

+ self.flush_peer_distribution_queue()

+ RNS.log("Calculating peer distribution queue mappings...", RNS.LOG_DEBUG); st = time.time()

+ for peer_id in self.peers.copy():

+ if peer_id in self.peers:

+ peer = self.peers[peer_id]

+ if peer.queued_items():

+ peer.process_queues()

+ RNS.log(f"Distribution queue mapping completed in {RNS.prettytime(time.time()-st)}", RNS.LOG_DEBUG)

def clean_links(self):

closed_links = []

──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────